<?php


namespace app\controller;

use support\Db;
use support\Request;
use Webman\RedisQueue\Client;

class Test
{
    public function index(Request $request)
    {
        $result = Db::table('test')->get();
        return response($result);
    }

    // redis消费队列
    public function queue() {
        // 队列名
        $queue = 'send_mail';
        // 数据，可以直接传数组，无需序列化
        $data = ['to' => 'tom@gmail.com', 'content' => 'hello'];
        // 投递消息 10s后处理
        Client::send($queue, $data, 10);
    }

}